package utils;

import com.hw.model.MessageWapper;
import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.util.Collector;

import java.util.Iterator;

public class DataDimReductionFunction extends ProcessFunction<Iterable<MessageWapper>, Iterable<MessageWapper>> {


    @Override
    public void processElement(Iterable<MessageWapper> value, ProcessFunction<Iterable<MessageWapper>, Iterable<MessageWapper>>.Context ctx, Collector<Iterable<MessageWapper>> out) throws Exception {
        
    }
}
